package bankowosc.polaczenie;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import bankowosc.dane.Ubezpieczenie_wplata;

public class Ubezpieczenie_wplataBD {

	public ArrayList<Ubezpieczenie_wplata> pobierzUbezpWplaty(polacz p, int id_ubezp) {
		ArrayList<Ubezpieczenie_wplata> ubezpwplaty = new ArrayList<>();
		Statement stmt = p.getStmt();
		String komenda = "select * from ubezpieczenie_wplata where id_ubezpieczenia="+id_ubezp;
		try {
			ResultSet rs = stmt.executeQuery(komenda);
			while(rs.next()) {
				ubezpwplaty.add(new Ubezpieczenie_wplata(rs.getInt(1),rs.getString(2),rs.getInt(3),
						rs.getString(4),rs.getFloat(5)));
			}
			rs.close();
			return ubezpwplaty;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}
	
	public boolean dodajWplate(polacz p, int id_ubezp) {
		Connection c = p.getC();
		try {
			CallableStatement ctmt = c.prepareCall("{call dodaj_wplate_ubezp(?)}");
			ctmt.setInt(1, id_ubezp);
			ctmt.execute();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
	}
}
